package com.example.example04;

import java.io.IOException;

import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

public class RawLogTextReducer extends Reducer<Text,Text,NullWritable,Text> {
  @Override
  public void reduce(Text key,Iterable<Text> values,Context context) throws IOException, InterruptedException{
    for(Text tx : values)
      context.write(NullWritable.get(),tx);
  }
}
